package com.infoauto.opc.gateway.messages.handler;


import com.infoauto.opc.gateway.messages.util.GenericsUtils;


public abstract class MqttListener<T> {

    //到达事件
    public abstract void messageArrived(String topic, T message);

   //消息传递完成
    public abstract void deliveryComplete(String topic);

    //泛型
    public Class getGenericType() {
        return GenericsUtils.getSuperClassGenericType(getClass());
    }
}
